package config

import (
	"encoding/json"
	"os"

	"github.com/wonderivan/logger"
)

type ConfigModel struct {
	Host     string        `json:"host"`
	Port     uint16        `json:"port"`
	User     string        `json:"user"`
	Password string        `json:"password"`
	Topics   []RecordTopic `json:"topics"`
}

type RecordTopic struct {
	Topic  string `json:"topic"`
	Format string `json:"format"`
}

func LoadCfg(file string) *ConfigModel {
	//读取服务列表配置
	if buffer, err := os.ReadFile(file); err != nil {
		logger.Fatal("服务列表读取错误" + err.Error())
	} else {
		res := new(ConfigModel)
		if err = json.Unmarshal(buffer, res); err != nil {
			logger.Fatal("服务列表读取错误")
		}
		return res
	}
	return nil
} //加载配置文件
